package main

import (
	"git.900sui.cn/kc/base/utils"
	"git.900sui.cn/kc/kcgin"
	"git.900sui.cn/kc/kcgin/logs"
	"git.900sui.cn/kc/rpcinterface/client/bus"
	"github.com/robfig/cron"
	"context"
)

//处理验证中的存管账户
func handleSettleAcctTask()  {
	new(utils.KcLog).GetInstance( kcgin.AppConfig.String("bus.log.pingppHandleSettleAcct"))
	rpcBus := new(bus.CustodyPingppClient).Init()
	args := ""
	reply := false
	err := rpcBus.HandleSettleAcct(context.Background(),args,&reply)
	if err != nil{
		utils.Logerr.Printf("ping++处理验证中的存管账户失败 err : %v.", err.Error())
		return
	}
	utils.Logerr.Printf("ping++处理验证中的存管账户成功")
}

func main() {
	logs.Info("Environment Variable:MSF_ENV:", kcgin.KcConfig.RunMode)
	c := cron.New()
	//每5分钟执行一次
	spec := "0 */10 * * * ?" //秒-分-时-日-月-周【忽略】
	_ = c.AddFunc(spec,handleSettleAcctTask)
	c.Start()
	select {}
}
